package com.aotain.jupiter.flink;

import java.util.ArrayList;
import java.util.List;

import org.apache.flink.streaming.api.collector.selector.OutputSelector;

public class SourceDataSelector implements OutputSelector<String>{


	/** 
	 * @Fields serialVersionUID : TODO(用一句话描述这个变量表示什么) 
	 */ 
	private static final long serialVersionUID = -4094770370236202307L;

	@Override
	public Iterable<String> select(String value) {

		List<String> output = new ArrayList<String>();
		output.add("DipStream");
		output.add("SipStream");

		return output;
	}

}
